072f0dfea9a06fdcf359cb16c7fde0976755b5fe,integration-tests/src/test/java/tachyon/client/RemoteBlockInStreamIntegrationTest.java,RemoteBlockInStreamIntegrationTest,readTest5,#,304

Before Change


      long blockId = mTfs.getInfo(f).getBlockIds().get(0);
      BlockInfo info = TachyonBlockStore.get().getInfo(blockId);
      RemoteBlockInStream is =
          new RemoteBlockInStream(info.getBlockId(), info.getLength(), info.getLocations().get(0)
              .getWorkerAddress());
      byte[] ret = new byte[k];
      int start = 0;
      while (start < k) {

After Change



      long blockId = mTfs.getInfo(f).getBlockIds().get(0);
      BlockInfo info = TachyonBlockStore.get().getInfo(blockId);
      NetAddress workerAddr = info.getLocations().get(0).getWorkerAddress();
      RemoteBlockInStream is =
          new RemoteBlockInStream(info.getBlockId(), info.getLength(), new InetSocketAddress(
              workerAddr.getHost(), workerAddr.getDataPort()));
      byte[] ret = new byte[k];
      int start = 0;
      while (start < k) {